"""
消费者:
    celery -A proj worker -l info.
    在虚拟环境下执行指令.
    celery -A celery实例的脚本路径 worker -l INFO
    -- celery -A celery_tasks.main worker -l INFO

    -- windows:
    celery -A your_project worker -l info -P solo
"""


# 0. 为celery设置运行环境.
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')

# 1. 创建celery实例
from celery import Celery
# 参数1: main 设置脚本路径就可以了. 脚本路径基本唯一.
app = Celery('celery_tasks')

# 2. 设置broker.
# 通过加载配置文件来设置broker.
app.config_from_object('celery_tasks.config')

# 3. 让celery自动检测包的任务.
# 列表中参数是 tasks的路径即可.
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.send_email'])
